package filehandler

import (
	"gitee.com/mjun1833/buildnotification/utils/dgfile/loggo"
	"os"
)

// 启动函数
func Start(handlerNum int) error {
	loggo.InitDefaultLog() // 初始化日志组件
	handler := &FileScanner{
		BatchNum:          handlerNum, // 同时处理的文件个数
		BaseDir:           "./",       // 扫描文件的根目录
		FileType:          "test_log", // 文件类型
		RemoveHandledFile: false,      // 是否删除已处理的文件
	}
	handler.FileValidation = fileValidation
	handler.HandleByteFunc = handleByteFunc
	handler.Init() // 初始化扫描器
	handler.Scan() // 开始扫描
	return nil
}

// 文件验证，过滤不需要处理的文件
func fileValidation(fileInfo os.FileInfo) bool {
	return true
}

// 一行数据的处理函数
func handleByteFunc(line []byte) error {
	return nil
}
